Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Emit when the CDC event was executed #930

Merged
merged 9 commits into from
Sep 26, 2024
Merged

Emit when the CDC event was executed #930

merged 9 commits into from
Sep 26, 2024

Conversation

Tang8330
Copy link
Contributor

@Tang8330 Tang8330 commented Sep 26, 2024

Emit this metric to Datadog, so we can see if there's a lag in reading source data.

@Tang8330 Tang8330 changed the title [WIP] Expose execution time. [WIP] Emit when the CDC event was executed. Sep 26, 2024
@Tang8330 Tang8330 changed the title [WIP] Emit when the CDC event was executed. [WIP] Emit when the CDC event was executed Sep 26, 2024
@Tang8330 Tang8330 changed the title [WIP] Emit when the CDC event was executed Emit when the CDC event was executed Sep 26, 2024
@Tang8330 Tang8330 marked this pull request as ready for review September 26, 2024 03:23
@Tang8330 Tang8330 requested a review from a team as a code owner September 26, 2024 03:23
}

// EmitExecutionTimeLag - This will check against the current time and the event execution time and emit the lag.
func (e *Event) EmitExecutionTimeLag(metricsClient base.Client, mode config.Mode) {
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Does the mode need to be passed in, or can we use e.mode?

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Good flag. We should be able to just use e.mode!

@Tang8330 Tang8330 merged commit 7589af6 into master Sep 26, 2024
3 checks passed
@Tang8330 Tang8330 deleted the ingestion-lag branch September 26, 2024 23:28
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants